package cn.monkey.transport.mq.rabbitmq;

import com.rabbitmq.client.Address;
import com.rabbitmq.client.Channel;
import reactor.core.publisher.Mono;

import java.util.Map;

public interface ReactiveRabbitMqChannelPool {

    Mono<Channel> findOrCreate(Address address, Map<String, Object> properties);

    Mono<Void> destroy(Channel... channels);
}
